package com.sxz.sbs.module.message.presenter;

import com.sxz.sbs.app.App;
import com.sxz.sbs.module.message.mode.MyMessageBean;
import com.sxz.sbs.module.message.view.MyMessageView;
import com.sxz.sbs.rx.RxPresenter;
import com.sxz.sbs.rx.RxSubscriber;
import com.sxz.sbs.rx.RxUtil;

import java.util.HashMap;
import java.util.List;

/**
 * 我的消息类型P
 */

public class MyMessagePresenter extends RxPresenter<MyMessageView>{
    /**
     * 获取消息类型
     * @param map
     */
    public void getMessageType (HashMap<String,Object> map) {
        addSubscribe(App.getInstance().getApi().getMessageType(map)
                .compose(RxUtil.<List<MyMessageBean>>handleResult())
                .subscribeWith(new RxSubscriber<List<MyMessageBean>>(mView){
                    @Override
                    public void onNext(List<MyMessageBean> token) {
                        mView.onGetMyMessageSuccess(token);
                    }
                })
        );
    }
}
